package com.zxy.db2;

import java.sql.Connection;
import java.sql.DatabaseMetaData;
import java.sql.Driver;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.util.Date;
import java.util.Enumeration;
import java.util.Vector;

public class ConnectionPool2
{
	public String						jdbcDriver				= "";	// 数据库驱动
	private String						dbUrl					= "";	// 数据
	private String						dbUsername				= "";	// 数据库用户名
	private String						dbPassword				= "";
	private int							initialConnections		= 5;	// 连接池的初始大小
	private int							incrementalConnections	= 5;	// 连接池自动增加的大小
	private int							maxConnections			= 10;	// Com_Fun.get_maxConnections(tdc.getDB_DriverClassName());//
																		// 连接池最大的大小
	private Vector<PooledConnection2>	connections				= null; // 存放连接池中数据库连接的向量

	// 构造函数 String JDBC 驱动类串 String 数据库 URL String 连接数据库用户名 String 连接数据库用户的密码
	public ConnectionPool2(String jdbcDriver, String dbUrl, String dbUsername, String dbPassword)
	{
		if(jdbcDriver.equals("org.sqlite.JDBC"))
		{
			initialConnections = 1;
			maxConnections = 1;
		}
		this.jdbcDriver = jdbcDriver;
		this.dbUrl = dbUrl;
		this.dbUsername = dbUsername;
		this.dbPassword = dbPassword;
		try
		{
			createPool();
		}
		catch(Exception e)
		{
			e.printStackTrace();
		}
	}

	// 返回连接池的初始大小
	public int getInitialConnections()
	{
		return this.initialConnections;
	}

	// 用于设置初始连接池中连接的数量
	public void setInitialConnections(int initialConnections)
	{
		this.initialConnections = initialConnections;
	}

	// 返回连接池自动增加的大小 、
	public int getIncrementalConnections()
	{
		return this.incrementalConnections;
	}

	// 设置连接池自动增加的大小
	public void setIncrementalConnections(int incrementalConnections)
	{
		this.incrementalConnections = incrementalConnections;
	}

	// 连接池中最大的可用连接数量
	public int getMaxConnections()
	{
		return this.maxConnections;
	}

	// 设置连接池中最大可用的连接数量值
	public void setMaxConnections(int maxConnections)
	{
		this.maxConnections = maxConnections;
	}

	// 创建一个数据库连接池，连接池中的可用连接的数量采用类成员 initialConnections 中设置的值
	public synchronized void createPool() throws Exception
	{
		// 确保连接池没有创建
		// 如果连接池己经创建了，保存连接的向量 connections 不会为空
		if(connections != null)
		{
			return; // 如果己经创建，则返回
		}
		// 实例化 JDBC Driver 中指定的驱动类实例
		Driver driver = (Driver) (Class.forName(this.jdbcDriver).newInstance());
		DriverManager.registerDriver(driver); // 注册 JDBC 驱动程序
		// 创建保存连接的向量 , 初始时有 0 个元素
		connections = new Vector<PooledConnection2>();
		// 根据 initialConnections 中设置的值，创建连接。
		createConnections(this.initialConnections);
		System.out.println("the 2create pool");
	}

	// 创建由 numConnections 指定数目的数据库连接 , 并把这些连接 放入 connections 向量中
	private void createConnections(int numConnections) throws SQLException
	{
		// 循环创建指定数目的数据库连接
		for(int x = 0;x < numConnections;x++)
		{
			// 如果连接数己经达到最大，即退出。
			if(this.maxConnections > 0
					&& this.connections.size() >= this.maxConnections)
			{
				System.out.println("the 2连接数己经达到最大");
				break;
			}
			// 增加一个连接到连接池中（向量 connections 中）
			try
			{
				connections.addElement(new PooledConnection2(newConnection()));
			}
			catch(SQLException e)
			{
				System.out.println("the 2创建数据库连接失败！ " + e.getMessage());
				throw new SQLException();
			}
		}
	}

	// 创建一个新的数据库连接并返回它
	private Connection newConnection() throws SQLException
	{
		// 创建一个数据库连接
		Connection conn = DriverManager.getConnection(dbUrl,dbUsername,dbPassword);
		// 如果这是第一次创建数据库连接，即检查数据库，获得此数据库允许支持的
		// 最大客户连接数目
		if(connections.size() == 0)
		{
			DatabaseMetaData metaData = conn.getMetaData();
			int driverMaxConnections = metaData.getMaxConnections();
			// 数据库返回的 driverMaxConnections 若为 0 ，表示此数据库没有最大
			// 连接限制，或数据库的最大连接限制不知道
			// driverMaxConnections 为返回的一个整数，表示此数据库允许客户连接的数目
			// 如果连接池中设置的最大连接数量大于数据库允许的连接数目 , 则置连接池的最大
			// 连接数目为数据库允许的最大数目
			if(driverMaxConnections > 0
					&& this.maxConnections > driverMaxConnections)
			{
				this.maxConnections = driverMaxConnections;
			}
		}
		return conn; // 返回创建的新的数据库连接
	}

	// 通过调用 getFreeConnection() 函数返回一个可用的数据库连接 , 如果当前没有可用的数据库连接，并且更多的数据库连接不能创
	public synchronized PooledConnection2 getConnection() throws SQLException
	{
		// 确保连接池己被创建
		if(connections == null)
		{
			return null; // 连接池还没创建，则返回 null
		}
		PooledConnection2 conn = getFreeConnection(); // 获得一个可用的数据库连接
		// 如果目前没有可以使用的连接，即所有的连接都在使用中
		while(conn == null)
		{
			// 等一会再试
			wait(150);
			conn = getFreeConnection(); // 重新再试，直到获得可用的连接，如果
			// getFreeConnection() 返回的为 null
			// 则表明创建一批连接后也不可获得可用连接
		}
		return conn;// 返回获得的可用的连接
	}

	private PooledConnection2 getFreeConnection() throws SQLException
	{
		// 从连接池中获得一个可用的数据库连接
		PooledConnection2 conn = findFreeConnection();
		if(conn == null)
		{
			// 如果目前连接池中没有可用的连接
			// 创建一些连接
			createConnections(incrementalConnections);
			// 重新从池中查找是否有可用连接
			conn = findFreeConnection();
			if(conn == null)
			{
				// 如果创建连接后仍获得不到可用的连接，则返回 null
				return null;
			}
		}
		return conn;
	}

	// 查找连接池中所有的连接，查找一个可用的数据库连接， 如果没有可用的连接，返回 null * @return 返回一个可用的数据库连接
	private PooledConnection2 findFreeConnection() throws SQLException
	{
		// 获得连接池向量中所有的对象
		for(int i = 0;i < connections.size();i++)
		{
			PooledConnection2 pc = connections.elementAt(i);
			if(!pc.isBusy())
			{
				// 如果此对象不忙，则获得它的数据库连接并把它设为忙
				Connection conn = pc.getConnection();
				pc.setBusy(true);
				// 测试此连接是否可用
				if(!isValid(conn))
				{
					// 如果此连接不可再用了，则创建一个新的连接，
					// 并替换此不可用的连接对象，如果创建失败，删除该无效连接，遍历下一个不忙连接
					try
					{
						conn = newConnection();
						pc.setConnection(conn);
					}
					catch(SQLException e)
					{
						e.printStackTrace();
						connections.remove(i--);
						continue;
					}
				}
				return pc;
			}
		}
		return null;// 返回找到到的可用连接
	}

	// 测试一个连接是否可用，如果不可用，关掉它并返回 false 否则可用返回 true
	private boolean isValid(Connection conn)
	{
		try
		{
			if(this.jdbcDriver.equals("org.sqlite.JDBC"))
				return !conn.isClosed();
			else if(this.jdbcDriver.indexOf("oracle") != -1)
				return conn.isValid(1000);
			else
				return !conn.isClosed();
		}
		catch(SQLException e)
		{
			e.printStackTrace();
			return false;
		}
	}

	// 此函数返回一个数据库连接到连接池中，并把此连接置为空闲。 所有使用连接池获得的数据库连接均应在不使用此连接时返回它。
	public void returnConnection(Connection conn)
	{
		// 确保连接池存在，如果连接没有创建（不存在），直接返回
		if(connections == null)
		{
			System.out.println("the 2连接池不存在，无法返回此连接到连接池中 !");
			return;
		}
		PooledConnection2 pConn = null;
		Enumeration<PooledConnection2> enumerate = connections.elements();
		// 遍历连接池中的所有连接，找到这个要返回的连接对象
		// int iUser = 0, iClose = 0;
		while(enumerate.hasMoreElements())
		{
			pConn = (PooledConnection2) enumerate.nextElement();
			// 先找到连接池中的要返回的连接对象
			if(conn == pConn.getConnection())
			{
				// 找到了 , 设置此连接为空闲状态
				pConn.setBusy(false);
			}
		}
	}

	// 刷新连接池中所有的连接对象
	public synchronized void refreshConnections() throws SQLException
	{
		// 确保连接池己创新存在
		if(connections == null)
		{
			System.out.println("the 2连接池不存在，无法刷新 !");
			return;
		}
		PooledConnection2 pConn = null;
		Enumeration<PooledConnection2> enumerate = connections.elements();
		while(enumerate.hasMoreElements())
		{
			// 获得一个连接对象
			pConn = (PooledConnection2) enumerate.nextElement();
			// 如果对象忙则等 5 秒 ,5 秒后直接刷新
			if(pConn.isBusy())
			{
				wait(5000); // 等 5 秒
			}
			// 关闭此连接，用一个新的连接代替它。
			closeConnection(pConn.getConnection());
			pConn.setConnection(newConnection());
			pConn.setBusy(false);
		}
	}

	// 关闭连接池中所有的连接，并清空连接池。
	public synchronized void closeConnectionPool() throws SQLException
	{
		// 确保连接池存在，如果不存在，返回
		if(connections == null)
		{
			System.out.println("the 2连接池不存在，无法关闭 !");
			return;
		}
		PooledConnection2 pConn = null;
		Enumeration<PooledConnection2> enumerate = connections.elements();
		while(enumerate.hasMoreElements())
		{
			pConn = (PooledConnection2) enumerate.nextElement();
			// 如果忙，等 5 秒
			if(pConn.isBusy())
			{
				wait(5000); // 等 5 秒
			}
			// 5 秒后直接关闭它
			closeConnection(pConn.getConnection());
			// 从连接池向量中删除它
			connections.removeElement(pConn);
		}
		// 置连接池为空
		connections = null;
	}

	// 关闭一个数据库连接
	private void closeConnection(Connection conn)
	{
		try
		{
			conn.close();
		}
		catch(SQLException e)
		{
			System.out.println("the 2关闭数据库连接出错： " + e.getMessage());
		}
	}

	// 超时连接。
	public synchronized void closeConnectionPoolTimeOut() throws SQLException
	{
		PooledConnection2 pConn = null;
		if(connections != null && !this.jdbcDriver.equals("org.sqlite.JDBC"))
		{
			int iIndex = 0;
			Enumeration<PooledConnection2> enumerate = connections.elements();
			while(enumerate.hasMoreElements())
			{
				pConn = (PooledConnection2) enumerate.nextElement();
				if(pConn.updtime + 180000 < new Date().getTime())// 300000
				{
					isValid(pConn.getConnection());
					if(iIndex < initialConnections)
					{
						try
						{
							pConn.executeQuery(new StringBuilder("select 1"));
						}
						catch(Exception e)
						{
							e.printStackTrace();
						}
						finally
						{
							pConn.returnConnection();
						}
					}
					// 超过initialConnections个连接关闭
					else
					{
						closeConnection(pConn.getConnection());
						connections.removeElement(pConn);
					}
				}
				iIndex++;
			}
		}
	}

	// 使程序等待给定的毫秒数
	private void wait(int mSeconds)
	{
		try
		{
			Thread.sleep(mSeconds);
		}
		catch(Exception e)
		{
		}
	}
}